package cn.doit.etl

import cn.doit.common.DolphinAppComm
import org.apache.spark.sql.SQLContext

object SQL4PArquet {
  def main(args: Array[String]): Unit = {
    val sc = DolphinAppComm.creatSparkContext("cn.doit.etl.SQL4PArquet")
    val sqlc = new SQLContext(sc)
    val dataFrame = sqlc.read.parquet("abc")
    dataFrame.show(100)

    sc.stop()

  }
}
